# celery的任务必须卸载tasks的文件中，其他文件名不识别
from my_celery.main import app
from django.conf import settings
from .yuntongxun.sms import CCP
import logging

log = logging.getLogger("django")

@app.task(name="send_sms_code")  # 设置的任务名称，如果不填写，默认使用函数名作为任务名 my_celery.sms.tasks.send_sms
def send_sms_code(mobile, sms_code):
    try:
        ccp = CCP()
        ret = ccp.send_template_sms(mobile,
                                    [sms_code, settings.SMS['sms_expire_time'] // 60], settings.SMS['sms_template_id'])
    except:
        log.error('发送短信异常,用户:%s，验证码:%s' %(mobile, sms_code))

    print("发送短信给%s" % mobile)


@app.task(name="send_sms_password")  # name设置任务的名称
def send_sms_password():
    print("发送短信2...")
